#!/usr/bin/python
#coding: utf-8

"""
1.对百度贴吧的任意帖子进行抓取
2.指定是否只抓取楼主发帖内容
3.将抓取到的内容分析并保存到文件

http://  代表资源传输使用http协议
tieba.baidu.com 是百度的二级域名，指向百度贴吧的服务器
/p/3138733512 是服务器某个资源，即这个帖子的地址定位符
see_lz和pn是该URL的两个参数，分别代表了只看楼主和帖子页码，seelz等于1表示该条件为真

注意：原网页的源代码格式不太正规，或者是代码有错误，爬取部分网页的时候出现一些小错误，
不过作为练习正则来说的话，已经足够了
"""

import re
import urllib2

#处理页面标签类
class Tool:
    """
    在类BDTB类getContent方法中，获取的内容中间有很多需要修改的地方，
    这里定义一个工具类进行相应的修改，使它变为标准的中文格式
    """
    #去除img标签,7位长空格
    removeImg = re.compile('<img.*?>| {7}|')
    #删除超链接标签
    removeAddr = re.compile('<a.*?>|</a>')
    #把换行的标签换为\n
    replaceLine = re.compile('<tr>|<div>|</div>|</p>')
    #将表格制表<td>替换为\t
    replaceTD= re.compile('<td>')
    #把段落开头换为\n加空两格
    replacePara = re.compile('<p.*?>')
    #将换行符或双换行符替换为\n
    replaceBR = re.compile('<br><br>|<br>')
    #将其余标签剔除
    removeExtraTag = re.compile('<.*?>')
    def replace(self,x):
        x = re.sub(self.removeImg,"",x)
        x = re.sub(self.removeAddr,"",x)
        x = re.sub(self.replaceLine,"\n",x)
        x = re.sub(self.replaceTD,"\t",x)
        x = re.sub(self.replacePara,"\n    ",x)
        x = re.sub(self.replaceBR,"\n",x)
        x = re.sub(self.removeExtraTag,"",x)
        #strip()将前后多余内容删除
        return x.strip()

# 百度贴吧爬虫类
class BDTB(object):
    # 初始化，baseUrl 用来传入基地址
    # seelz 是否只看楼主的参数
    def __init__(self, baseUrl, seelz, floorTag):
        # base链接地址
        self.baseURL = baseUrl
        # 是否只看楼主
        self.seeLZ = '?see_lz=' + str(seeLZ)
        # HTML标签剔除工具类对象
        self.tool = Tool()
        # 全局file变量，文件写入操作对象
        self.file = None
        # 楼层标号，初始为1
        self.floor = 1
        # 默认的标题，如果没有成功获取到标题的话则会用这个标题
        self.defaultTitle = u"百度贴吧"
        # 是否写入楼分隔符的标记
        self.floorTag = floorTag
        # 防止访问识别
        self.headers = {'User-Agent' : 'Mozilla/4.0 (compatible; MSIE 5.5; Windows NT)',
           'Referer' : 'http://tieba.baidu.com/p/3138733512'}

    # 传入页码，获取该页帖子的代码
    def getPage(self, pageNum):
        try:
            # 获取页面的页码
            url = self.baseURL + self.seeLZ + "&pn=" + str(pageNum)
            request = urllib2.Request(url, headers= self.headers)
            response = urllib2.urlopen(request)
            # 测试输出
            # print response.read().decode('utf-8')
            return response.read().decode('utf-8')
        except urllib2.URLError, e:
            if hasattr(e, "reason"):
                print u"连接百度贴吧出错,错误原因", e.reason
                return None

    # 获取帖子的标题
    def getTitle(self, page):
        pattern = re.compile('<h3 class="core_title_txt.*?>(.*?)</h3>', re.S)
        result = re.search(pattern, page)
        # print type(result)

        if result:
            # print result.group(1)  #测试输出
            return result.group(1).strip()
        else:
            return None

    # 获取帖子的页码
    def getPageNum(self, page):
        pattern = re.compile('<li class="l_reply_num.*?</span>.*?<span.*?>(.*?)</span>', re.S)
        result = re.search(pattern, page)
        if result:
            # print result.group(1)  #测试输出
            return result.group(1).strip()
        else:
            return None

    # 获取每一层楼的内容,传入页面内容
    def getContent(self, page):
        pattern = re.compile('<div id="post_content_.*?>(.*?)</div>', re.S)
        items = re.findall(pattern, page)
        contents = []
        for item in items:
            # 测试输出
            # print type(item)
            # print item
            st = self.tool.replace(item)
            if st is None:
                continue
            content = "\n" + st + "\n"
            contents.append(content.encode("utf-8"))
        return contents

    # 设置文件名
    def setFileTitle(self, title):
        # 如果标题不是为None，即成功获取到标题
        if title is not None:
            self.file = open(title + ".txt", "w+")
        else:
            self.file = open(self.defaultTitle + ".txt", "w+")

    # 向文件中写入数据
    def writeData(self, contents):
        # 向文件写入每一楼的信息
        for item in contents:
            if self.floorTag == '1':
                # 楼之间的分隔符
                floorLine = "\n" + str(
                    self.floor) + u"楼 -----------------------------------------------------------------------------------------\n"
                self.file.write(floorLine.encode("utf-8"))
            self.file.write(item)
            self.floor += 1

    def start(self):
        indexPage = self.getPage(1)
        # print len(indexPage)
        pageNum = self.getPageNum(indexPage)
        # print pageNum
        title = self.getTitle(indexPage)
        self.setFileTitle(title)
        if pageNum == None:
            print "URL已失效，请重试"
            return
        try:
            print "该帖子共有" + str(pageNum) + "页"
            for i in range(1, int(pageNum) + 1):
                print "正在写入第" + str(i) + "页数据"
                page = self.getPage(i)
                contents = self.getContent(page)
                self.writeData(contents)
        # 出现写入异常
        except IOError, e:
            print "写入异常，原因" + e.message
        except Exception as e:
            # 如果出现其它错误的话，在此接收
            print e
        finally:
            self.file.close()
            print "写入任务完成"

if __name__ == "__main__":
    # 测试输出
    # baseURL = 'http://tieba.baidu.com/p/3138733512'
    # bdtb = BDTB(baseURL, 1)
    # # print bdtb.getPage(1)
    # # print bdtb.getTitle()
    # # print bdtb.getPageNum()
    # bdtb.getContent(bdtb.getPage(1))

    print u"请输入帖子代号"
    """
    测试用的帖子代号：
    3138733512
    3513281888
    4987044868
    4986877731
    """
    baseURL = 'http://tieba.baidu.com/p/' + str(raw_input(u'http://tieba.baidu.com/p/'))
    seeLZ = raw_input("是否只获取楼主发言，是输入1，否输入0\n")
    floorTag = raw_input("是否写入楼层信息，是输入1，否输入0\n")
    bdtb = BDTB(baseURL, seeLZ, floorTag)
    bdtb.start()